<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">

<!-- 
	Copyright (C) 2007, 2008, 2009, 2010, 2011. PARP Research Group.
	<http://perception.inf.um.es>
	University of Murcia, Spain.

	This file is part of the QVision library.

	QVision is free software: you can redistribute it and/or modify
	it under the terms of the GNU Lesser General Public License as
	published by the Free Software Foundation, version 3 of the License.

	QVision is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
	GNU Lesser General Public License for more details.

	You should have received a copy of the GNU Lesser General Public
	License along with QVision. If not, see <http://www.gnu.org/licenses/>.
-->

<html><head><meta http-equiv="content-Type" content="text/html;charset=UTF-8">
<title>QVision: Qt&#39;s Image, Video and Computer Vision Library</title>
<meta name="title" content="QVision" />
<meta name="dc.title" content="QVision" />
<meta name="url" content="http://perception.inf.um.es/QVision" />
<meta name="author" content="PARP Research Group - http://perception.inf.um.es" />
<meta name="revisit-after" content="30 DAYS"/>
<meta name="robots" content="index,follow"/>
<meta name="classification" content="*">
<meta name="rating" content="Safe For Kids">
<meta name="distribution" content="GLOBAL"/>
<meta name="description" content="Qt's Image, Video and Computer Vision Library"/>
<meta name="page-topic" content="Computer Vision research and prototype programming"/>
<meta name="geo.country" content="ES" />

<!--
Keywords:
By license:		open source, gnu, lgpl, gpl, free
By theme:		computer vision, image processing, robotics, programming, source, development
By usage:		library, toolkit, framework, prototype, application
By programming specs:	object oriented, c++, block programming, reusability, gui, graphical, parallel computing, high performance, GPU, prototyping
Interoperability with:	Qt, GSL, GNU Scientific library, OpenCV, CGAL, QWT, CUDA, mplayer, IPP, Intel Image Performance Primitives, blas, lapack
Functionallity:		image features, matrix algebra, projective geometry, mser, function minimization, function optimization, canny operator, harris operator, corner detection, performance evaluation, cpu usage, graphical interface
Main data-types:	matrix, vector, tensor, quaternion, image, polyline
Video sources:		webcam, camera, stream
Devices:		embedded, desktop computer, laptop, mini-laptop
Authors:		PARP research group. University of Murcia, Spain.
-->

<meta name="keywords" content="augmented reality, sfm, structure from motion, open source, gnu, lgpl, gpl, free, computer vision, image processing, robotics, programming, source, development, library, toolkit, framework, prototype, application, object oriented, c++, block programming, reusability, gui, graphical, parallel computing, high performance, GPU, prototyping, Qt, GSL, GNU Scientific library, OpenCV, CGAL, QWT, CUDA, mplayer, IPP, Intel Image Performance Primitives, blas, lapack, image features, matrix algebra, projective geometry, mser, function minimization, function optimization, canny operator, harris operator, corner detection, performance evaluation, cpu usage, graphical interface, matrix, vector, tensor, quaternion, image, polyline, webcam, camera, stream, embedded, desktop computer, laptop, mini-laptop, University of Murcia, Spain, PARP research group, vision por computador"/>
<meta http-equiv="keywords" content="augmented reality, sfm, structure from motion, open source, gnu, lgpl, gpl, free, computer vision, image processing, robotics, programming, source, development, library, toolkit, framework, prototype, application, object oriented, c++, block programming, reusability, gui, graphical, parallel computing, high performance, GPU, prototyping, Qt, GSL, GNU Scientific library, OpenCV, CGAL, QWT, CUDA, mplayer, IPP, Intel Image Performance Primitives, blas, lapack, image features, matrix algebra, projective geometry, mser, function minimization, function optimization, canny operator, harris operator, corner detection, performance evaluation, cpu usage, graphical interface, matrix, vector, tensor, quaternion, image, polyline, webcam, camera, stream, embedded, desktop computer, laptop, mini-laptop, University of Murcia, Spain, PARP research group, vision por computador"/>
<meta http-equiv="pragma" content="no-cache"/>
<meta http-equiv="title" content="QVision"/>
<link href="doxygen.css" rel="stylesheet" type="text/css" />
<link href="tabs.css" rel="stylesheet" type="text/css" />
<link rel="shortcut icon" href="favicon.ico" />
</head><body>

<table width="100%"><tr>
	<td><a href="http://perception.inf.um.es/"><img src="parp.png" border="0" /> <big>PARP Research Group</big></a></td>
	<td align="right"><a href="http://www.um.es/"><big>Universidad de Murcia</big> <img src="um.png" border="0" /></a></td>
</tr></table>

<hr /><br />

<table width="95%" align="center"><tr><td>

<!-- Generated by Doxygen 1.6.3 -->
<script type="text/javascript"><!--
var searchBox = new SearchBox("searchBox", "search",false,'Search');
--></script>
<div class="navigation" id="top">
  <div class="tabs">
    <ul>
      <li><a href="index.html"><span>Main&nbsp;Page</span></a></li>
      <li><a href="pages.html"><span>Related&nbsp;Pages</span></a></li>
      <li><a href="modules.html"><span>Modules</span></a></li>
      <li><a href="annotated.html"><span>Classes</span></a></li>
      <li class="current"><a href="files.html"><span>Files</span></a></li>
      <li>
        <div id="MSearchBox" class="MSearchBoxInactive">
          <form id="FSearchBox" action="search.php" method="get">
            <img id="MSearchSelect" src="search/search.png" alt=""/>
            <input type="text" id="MSearchField" name="query" value="Search" size="20" accesskey="S" 
                   onfocus="searchBox.OnSearchFieldFocus(true)" 
                   onblur="searchBox.OnSearchFieldFocus(false)"/>
          </form>
        </div>
      </li>
    </ul>
  </div>
  <div class="tabs">
    <ul>
      <li><a href="files.html"><span>File&nbsp;List</span></a></li>
      <li><a href="globals.html"><span>File&nbsp;Members</span></a></li>
    </ul>
  </div>
<h1>src/qvip/qvmplayer/qnamedpipe.cpp</h1><a href="qnamedpipe_8cpp.html">Go to the documentation of this file.</a><div class="fragment"><pre class="fragment"><a name="l00001"></a>00001 <span class="comment">/*</span>
<a name="l00002"></a>00002 <span class="comment"> *      Copyright (C) 2007, 2008, 2009, 2010, 2011, 2012. PARP Research Group.</span>
<a name="l00003"></a>00003 <span class="comment"> *      &lt;http://perception.inf.um.es&gt;</span>
<a name="l00004"></a>00004 <span class="comment"> *      University of Murcia, Spain.</span>
<a name="l00005"></a>00005 <span class="comment"> *</span>
<a name="l00006"></a>00006 <span class="comment"> *      This file is part of the QVision library.</span>
<a name="l00007"></a>00007 <span class="comment"> *</span>
<a name="l00008"></a>00008 <span class="comment"> *      QVision is free software: you can redistribute it and/or modify</span>
<a name="l00009"></a>00009 <span class="comment"> *      it under the terms of the GNU Lesser General Public License as</span>
<a name="l00010"></a>00010 <span class="comment"> *      published by the Free Software Foundation, version 3 of the License.</span>
<a name="l00011"></a>00011 <span class="comment"> *</span>
<a name="l00012"></a>00012 <span class="comment"> *      QVision is distributed in the hope that it will be useful,</span>
<a name="l00013"></a>00013 <span class="comment"> *      but WITHOUT ANY WARRANTY; without even the implied warranty of</span>
<a name="l00014"></a>00014 <span class="comment"> *      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the</span>
<a name="l00015"></a>00015 <span class="comment"> *      GNU Lesser General Public License for more details.</span>
<a name="l00016"></a>00016 <span class="comment"> *</span>
<a name="l00017"></a>00017 <span class="comment"> *      You should have received a copy of the GNU Lesser General Public</span>
<a name="l00018"></a>00018 <span class="comment"> *      License along with QVision. If not, see &lt;http://www.gnu.org/licenses/&gt;.</span>
<a name="l00019"></a>00019 <span class="comment"> */</span>
<a name="l00020"></a>00020 
<a name="l00024"></a>00024 
<a name="l00025"></a>00025 <span class="preprocessor">#ifdef unix</span>
<a name="l00026"></a>00026 <span class="preprocessor"></span><span class="preprocessor">#include &lt;sys/types.h&gt;</span>
<a name="l00027"></a>00027 <span class="preprocessor">#include &lt;sys/stat.h&gt;</span>
<a name="l00028"></a>00028 <span class="preprocessor">#include &lt;stdlib.h&gt;</span>
<a name="l00029"></a>00029 <span class="preprocessor">#include &lt;fcntl.h&gt;</span>
<a name="l00030"></a>00030 <span class="preprocessor">#include &lt;stdio.h&gt;</span>
<a name="l00031"></a>00031 <span class="preprocessor">#elif WIN32</span>
<a name="l00032"></a>00032 <span class="preprocessor"></span><span class="preprocessor">#include &lt;QThread&gt;</span>
<a name="l00033"></a>00033 <span class="preprocessor">#include &lt;windows.h&gt;</span>
<a name="l00034"></a>00034 <span class="preprocessor">#include &lt;tchar.h&gt;</span>
<a name="l00035"></a>00035 <span class="preprocessor">#endif</span>
<a name="l00036"></a>00036 <span class="preprocessor"></span>
<a name="l00037"></a>00037 <span class="comment">// header</span>
<a name="l00038"></a>00038 <span class="preprocessor">#include &lt;QNamedPipe&gt;</span>
<a name="l00039"></a>00039 <span class="preprocessor">#include &lt;QDebug&gt;</span>
<a name="l00040"></a>00040 <span class="preprocessor">#include &lt;unistd.h&gt;</span>     <span class="comment">// for getpid</span>
<a name="l00041"></a>00041 
<a name="l00043"></a>00043 <span class="comment">// QNamedPipeThread</span>
<a name="l00044"></a>00044 <span class="preprocessor">#ifdef WIN32</span>
<a name="l00045"></a>00045 <span class="preprocessor"></span>TCHAR * char_to_tchar(<span class="keyword">const</span> <span class="keywordtype">char</span>* pSrc)
<a name="l00046"></a>00046         {
<a name="l00047"></a>00047         <span class="keywordflow">if</span>(!pSrc) <span class="keywordflow">return</span> NULL;
<a name="l00048"></a>00048         <span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> n = strlen (pSrc);
<a name="l00049"></a>00049         TCHAR * wsOut = <span class="keyword">new</span> TCHAR[n+1];
<a name="l00050"></a>00050         <span class="keywordflow">for</span> (<span class="keywordtype">unsigned</span> <span class="keywordtype">int</span> i=0; i&lt;1+n; i++)
<a name="l00051"></a>00051                 wsOut[i] = pSrc[i];
<a name="l00052"></a>00052 
<a name="l00053"></a>00053         <span class="keywordflow">return</span> wsOut;
<a name="l00054"></a>00054         };
<a name="l00055"></a>00055 
<a name="l00056"></a>00056 <span class="preprocessor">#define BUFSIZE 256*1024</span>
<a name="l00057"></a>00057 <span class="preprocessor"></span>
<a name="l00058"></a>00058 QNamedPipeThread::QNamedPipeThread(HANDLE pipe1, HANDLE pipe2, <span class="keywordtype">char</span> *name)
<a name="l00059"></a>00059         {
<a name="l00060"></a>00060         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipeThread(&quot;</span> &lt;&lt; pipe1 &lt;&lt; <span class="stringliteral">&quot;,&quot;</span> &lt;&lt; pipe2 &lt;&lt; <span class="stringliteral">&quot;,&quot;</span> &lt;&lt; name &lt;&lt; <span class="stringliteral">&quot;)&quot;</span>;
<a name="l00061"></a>00061         this-&gt;hPipe1 = pipe1;
<a name="l00062"></a>00062         this-&gt;hPipe2 = pipe2;
<a name="l00063"></a>00063         this-&gt;finished = <span class="keyword">false</span>;
<a name="l00064"></a>00064         this-&gt;pipeName = strdup(name);
<a name="l00065"></a>00065         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipeThread() &lt;- return&quot;</span>;
<a name="l00066"></a>00066         }
<a name="l00067"></a>00067         
<a name="l00068"></a>00068 QNamedPipeThread::~QNamedPipeThread()
<a name="l00069"></a>00069         {
<a name="l00070"></a>00070         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::~QNamedPipeThread()&quot;</span>;
<a name="l00071"></a>00071         <span class="keyword">delete</span> this-&gt;pipeName;
<a name="l00072"></a>00072         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::~QNamedPipeThread() &lt;- return&quot;</span>;
<a name="l00073"></a>00073         }
<a name="l00074"></a>00074         
<a name="l00075"></a>00075         
<a name="l00076"></a>00076 <span class="keywordtype">void</span> QNamedPipeThread::run()
<a name="l00077"></a>00077         {
<a name="l00078"></a>00078         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run()&quot;</span>;
<a name="l00079"></a>00079 
<a name="l00080"></a>00080         <span class="comment">// we receive conexion from programs using the pipe</span>
<a name="l00081"></a>00081         BOOL    fConnected1 = ConnectNamedPipe(hPipe1, NULL) ?
<a name="l00082"></a>00082                                 TRUE : (GetLastError() == ERROR_PIPE_CONNECTED); 
<a name="l00083"></a>00083         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): input end for pipe&quot;</span> &lt;&lt; pipeName &lt;&lt; <span class="stringliteral">&quot;connected&quot;</span>;
<a name="l00084"></a>00084 
<a name="l00085"></a>00085         BOOL    fConnected2 = ConnectNamedPipe(hPipe2, NULL) ?
<a name="l00086"></a>00086                                 TRUE : (GetLastError() == ERROR_PIPE_CONNECTED); 
<a name="l00087"></a>00087         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): output end for pipe&quot;</span> &lt;&lt; pipeName &lt;&lt; <span class="stringliteral">&quot;connected&quot;</span>;
<a name="l00088"></a>00088 
<a name="l00089"></a>00089         <span class="keywordflow">if</span> (!fConnected1 || !fConnected2)
<a name="l00090"></a>00090                 {
<a name="l00091"></a>00091                 qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): connection for named pipe &quot;</span> &lt;&lt; pipeName &lt;&lt; <span class="stringliteral">&quot;failed&quot;</span>;
<a name="l00092"></a>00092                 <span class="keywordflow">return</span>;
<a name="l00093"></a>00093                 }
<a name="l00094"></a>00094 
<a name="l00095"></a>00095         <span class="comment">// main loop: we read data from input pipe (1) and send it to output pipe (2)</span>
<a name="l00096"></a>00096         <span class="keywordtype">int</span> c = 0;
<a name="l00097"></a>00097         
<a name="l00098"></a>00098         <span class="keywordflow">while</span> (not finished) 
<a name="l00099"></a>00099                 {
<a name="l00100"></a>00100                 qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): dispatching loop for named pipe &quot;</span> &lt;&lt; pipeName &lt;&lt; <span class="stringliteral">&quot;started&quot;</span>;
<a name="l00101"></a>00101 
<a name="l00102"></a>00102                 TCHAR buffer[BUFSIZE]; 
<a name="l00103"></a>00103                 DWORD cbBytesRead, cbWritten;
<a name="l00104"></a>00104                 <span class="comment">//while (cbBytesRead &lt; 0) </span>
<a name="l00105"></a>00105                 <span class="comment">// Read client requests from the pipe. </span>
<a name="l00106"></a>00106                 BOOL fSuccess = ReadFile( 
<a name="l00107"></a>00107                         hPipe1,         <span class="comment">// handle to pipe </span>
<a name="l00108"></a>00108                         buffer,         <span class="comment">// buffer to receive data </span>
<a name="l00109"></a>00109                         BUFSIZE*<span class="keyword">sizeof</span>(TCHAR), <span class="comment">// size of buffer </span>
<a name="l00110"></a>00110                         &amp;cbBytesRead,   <span class="comment">// number of bytes read </span>
<a name="l00111"></a>00111                         NULL);          <span class="comment">// not overlapped I/O </span>
<a name="l00112"></a>00112                 qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): read &quot;</span> &lt;&lt; cbBytesRead &lt;&lt; <span class="stringliteral">&quot;bytes from input of pipe&quot;</span> &lt;&lt; pipeName;
<a name="l00113"></a>00113                 
<a name="l00114"></a>00114                 FlushFileBuffers(hPipe1);
<a name="l00115"></a>00115                 qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): done flushing for input end of named pipe&quot;</span>&lt;&lt; pipeName;
<a name="l00116"></a>00116                 c += cbBytesRead;
<a name="l00117"></a>00117 
<a name="l00118"></a>00118                 <span class="keywordflow">if</span> (! fSuccess)
<a name="l00119"></a>00119                         {
<a name="l00120"></a>00120                         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): ReadFile false, exiting main loop for pipe&quot;</span>&lt;&lt; pipeName;
<a name="l00121"></a>00121                         finished = <span class="keyword">true</span>;
<a name="l00122"></a>00122                         <span class="keywordflow">break</span>;
<a name="l00123"></a>00123                         }
<a name="l00124"></a>00124                 <span class="keywordflow">else</span> <span class="keywordflow">if</span> (cbBytesRead == 0)
<a name="l00125"></a>00125                         {
<a name="l00126"></a>00126                         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): 0 bytes read, exiting main loop for pipe&quot;</span>&lt;&lt; pipeName;
<a name="l00127"></a>00127                         finished = <span class="keyword">true</span>;
<a name="l00128"></a>00128                         <span class="keywordflow">break</span>;
<a name="l00129"></a>00129                         }
<a name="l00130"></a>00130                 <span class="keywordflow">else</span>
<a name="l00131"></a>00131                         {
<a name="l00132"></a>00132                         fSuccess = WriteFile( 
<a name="l00133"></a>00133                                 hPipe2,         <span class="comment">// handle to pipe </span>
<a name="l00134"></a>00134                                 buffer,         <span class="comment">// buffer to write from </span>
<a name="l00135"></a>00135                                 cbBytesRead,    <span class="comment">// number of bytes to write</span>
<a name="l00136"></a>00136                                 &amp;cbWritten,     <span class="comment">// number of bytes written</span>
<a name="l00137"></a>00137                                 NULL);          <span class="comment">// not overlapped I/O</span>
<a name="l00138"></a>00138                         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): sent&quot;</span> &lt;&lt; cbWritten &lt;&lt; <span class="stringliteral">&quot;bytes to output end of named pipe&quot;</span> &lt;&lt; pipeName;
<a name="l00139"></a>00139 
<a name="l00140"></a>00140                         FlushFileBuffers(hPipe2);
<a name="l00141"></a>00141                         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): done flushing for output end of named pipe&quot;</span>&lt;&lt; pipeName;
<a name="l00142"></a>00142 
<a name="l00143"></a>00143                         c -= cbWritten;
<a name="l00144"></a>00144 
<a name="l00145"></a>00145                         <span class="keywordflow">if</span> (c &gt; BUFSIZE)
<a name="l00146"></a>00146                                 qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): Buffer OVERFLOW&quot;</span> &lt;&lt; c &lt;&lt; <span class="stringliteral">&quot;of&quot;</span> &lt;&lt; BUFSIZE &lt;&lt; <span class="stringliteral">&quot;bytes max\n&quot;</span>;
<a name="l00147"></a>00147 
<a name="l00148"></a>00148                         <span class="keywordflow">if</span> (! fSuccess || cbBytesRead != cbWritten) <span class="keywordflow">break</span>;
<a name="l00149"></a>00149                         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): finished loop for pipe&quot;</span> &lt;&lt; pipeName;
<a name="l00150"></a>00150                         }
<a name="l00151"></a>00151                 }
<a name="l00152"></a>00152                 
<a name="l00153"></a>00153         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run(): closing pipe&quot;</span> &lt;&lt; pipeName;
<a name="l00154"></a>00154 
<a name="l00155"></a>00155         <span class="comment">// flushing and closing pipes</span>
<a name="l00156"></a>00156         FlushFileBuffers(hPipe1); 
<a name="l00157"></a>00157         FlushFileBuffers(hPipe2);
<a name="l00158"></a>00158         DisconnectNamedPipe(hPipe1);
<a name="l00159"></a>00159         DisconnectNamedPipe(hPipe2);
<a name="l00160"></a>00160         CloseHandle(hPipe1);
<a name="l00161"></a>00161         CloseHandle(hPipe2);
<a name="l00162"></a>00162         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::run() &lt;- return&quot;</span>;
<a name="l00163"></a>00163         }
<a name="l00164"></a>00164 <span class="preprocessor">#endif</span>
<a name="l00165"></a>00165 <span class="preprocessor"></span>
<a name="l00167"></a>00167 <span class="comment">// constructor and destructors</span>
<a name="l00168"></a>00168 QNamedPipe::QNamedPipe(QString identifier): QObject()
<a name="l00169"></a>00169         {
<a name="l00170"></a>00170         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipe(&quot;</span> &lt;&lt; identifier &lt;&lt;<span class="stringliteral">&quot;)&quot;</span>;
<a name="l00171"></a>00171 
<a name="l00172"></a>00172         name =  identifier + QString(<span class="stringliteral">&quot;.&quot;</span>)
<a name="l00173"></a>00173                 + QString().setNum(QNamedPipe::namedPipesNum++)
<a name="l00174"></a>00174                 + QString(<span class="stringliteral">&quot;.pid&quot;</span>) + QString().setNum(getpid());
<a name="l00175"></a>00175 
<a name="l00176"></a>00176 <span class="preprocessor">        #ifdef unix</span>
<a name="l00177"></a>00177 <span class="preprocessor"></span>        pathIn =        QString(<span class="stringliteral">&quot;/tmp/&quot;</span>) + name + QString(<span class="stringliteral">&quot;.qnamedpipe&quot;</span>);
<a name="l00178"></a>00178         pathOut =       QString(<span class="stringliteral">&quot;/tmp/&quot;</span>) + name + QString(<span class="stringliteral">&quot;.qnamedpipe&quot;</span>);
<a name="l00179"></a>00179         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipe(): (UNIX) going to create pipe&quot;</span> &lt;&lt; name
<a name="l00180"></a>00180                 &lt;&lt; <span class="stringliteral">&quot;\n\t&quot;</span>&lt;&lt; pathIn &lt;&lt; <span class="stringliteral">&quot;\n\t&quot;</span> &lt;&lt; pathOut;        
<a name="l00181"></a>00181 
<a name="l00182"></a>00182         mkfifo(pathIn.toAscii().data(),0644); pathOut = pathIn; 
<a name="l00183"></a>00183 
<a name="l00184"></a>00184 <span class="preprocessor">        #elif WIN32</span>
<a name="l00185"></a>00185 <span class="preprocessor"></span>        pathIn = QString(<span class="stringliteral">&quot;\\\\.\\pipe\\&quot;</span>) + name + QString(<span class="stringliteral">&quot;.in.qnamedpipe&quot;</span>);
<a name="l00186"></a>00186         pathOut = QString(<span class="stringliteral">&quot;\\\\.\\pipe\\&quot;</span>) + name + QString(<span class="stringliteral">&quot;.out.qnamedpipe&quot;</span>);
<a name="l00187"></a>00187         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipe(): (WIN32) going to create pipe&quot;</span> &lt;&lt; name
<a name="l00188"></a>00188                 &lt;&lt; <span class="stringliteral">&quot;\n\t&quot;</span>&lt;&lt; pathIn &lt;&lt; <span class="stringliteral">&quot;\n\t&quot;</span> &lt;&lt; pathOut;
<a name="l00189"></a>00189 
<a name="l00190"></a>00190         <span class="comment">// closing pipes</span>
<a name="l00191"></a>00191         HANDLE hPipe1 = CreateNamedPipe(
<a name="l00192"></a>00192                 TEXT(char_to_tchar(pathIn.toAscii().data())),   <span class="comment">// pipe name</span>
<a name="l00193"></a>00193                 PIPE_ACCESS_DUPLEX,                             <span class="comment">// read/write access </span>
<a name="l00194"></a>00194                 PIPE_TYPE_BYTE |                                <span class="comment">// message type pipe</span>
<a name="l00195"></a>00195                 PIPE_WAIT,                                      <span class="comment">// blocking mode</span>
<a name="l00196"></a>00196                 1,                                              <span class="comment">// max. instances</span>
<a name="l00197"></a>00197                 BUFSIZE,                                        <span class="comment">// output buffer size</span>
<a name="l00198"></a>00198                 BUFSIZE,                                        <span class="comment">// input buffer size </span>
<a name="l00199"></a>00199                 NMPWAIT_USE_DEFAULT_WAIT,                       <span class="comment">// client time-out</span>
<a name="l00200"></a>00200                 NULL);
<a name="l00201"></a>00201 
<a name="l00202"></a>00202         HANDLE hPipe2 = CreateNamedPipe(
<a name="l00203"></a>00203                 TEXT(char_to_tchar(pathOut.toAscii().data())),  <span class="comment">// pipe name</span>
<a name="l00204"></a>00204                 PIPE_ACCESS_DUPLEX,                             <span class="comment">// read/write access</span>
<a name="l00205"></a>00205                 PIPE_TYPE_BYTE |                                <span class="comment">// message type pipe</span>
<a name="l00206"></a>00206                 PIPE_WAIT,                                      <span class="comment">// blocking mode</span>
<a name="l00207"></a>00207                 1,                                              <span class="comment">// max. instances </span>
<a name="l00208"></a>00208                 BUFSIZE,                                        <span class="comment">// output buffer size</span>
<a name="l00209"></a>00209                 BUFSIZE,                                        <span class="comment">// input buffer size</span>
<a name="l00210"></a>00210                 NMPWAIT_USE_DEFAULT_WAIT,                       <span class="comment">// client time-out</span>
<a name="l00211"></a>00211                 NULL);
<a name="l00212"></a>00212 
<a name="l00213"></a>00213         <span class="comment">// check we closed the pipes</span>
<a name="l00214"></a>00214         <span class="keywordflow">if</span> ((hPipe1 == INVALID_HANDLE_VALUE) || (hPipe2 == INVALID_HANDLE_VALUE))
<a name="l00215"></a>00215                 {
<a name="l00216"></a>00216                 qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipe(): failed create of pipe&quot;</span> &lt;&lt; name;
<a name="l00217"></a>00217                 <span class="keywordflow">return</span>;
<a name="l00218"></a>00218                 }
<a name="l00219"></a>00219 
<a name="l00220"></a>00220         pipeThread = <span class="keyword">new</span> QNamedPipeThread(hPipe1,hPipe2,name.toAscii().data());
<a name="l00221"></a>00221         pipeThread-&gt;start(QThread::TimeCriticalPriority);
<a name="l00222"></a>00222 <span class="preprocessor">        #endif</span>
<a name="l00223"></a>00223 <span class="preprocessor"></span>        qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipe(): named pipe&quot;</span> &lt;&lt; name
<a name="l00224"></a>00224                 &lt;&lt; <span class="stringliteral">&quot;created:\n\t&quot;</span>&lt;&lt; pathIn &lt;&lt; <span class="stringliteral">&quot;\n\t&quot;</span> &lt;&lt; pathOut;        
<a name="l00225"></a>00225 
<a name="l00226"></a>00226         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::QNamedPipe() &lt;- return&quot;</span>;
<a name="l00227"></a>00227         }
<a name="l00228"></a>00228 
<a name="l00229"></a>00229 QNamedPipe::~QNamedPipe()
<a name="l00230"></a>00230         {
<a name="l00231"></a>00231         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::~QNamedPipe()&quot;</span>;
<a name="l00232"></a>00232         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::~QNamedPipe(): deleting pipe&quot;</span> &lt;&lt; name;
<a name="l00233"></a>00233         
<a name="l00234"></a>00234 <span class="preprocessor">        #ifdef unix</span>
<a name="l00235"></a>00235 <span class="preprocessor"></span>        <span class="keyword">remove</span>(pathIn.toAscii().data());
<a name="l00236"></a>00236 <span class="preprocessor">        #elif WIN32</span>
<a name="l00237"></a>00237 <span class="preprocessor"></span>        pipeThread-&gt;finished = <span class="keyword">true</span>;
<a name="l00238"></a>00238         pipeThread-&gt;wait();
<a name="l00239"></a>00239         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::~QNamedPipe(): pipeThread finished&quot;</span>;
<a name="l00240"></a>00240         <span class="keyword">delete</span> pipeThread;
<a name="l00241"></a>00241         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::~QNamedPipe(): pipeThread deleted&quot;</span>;
<a name="l00242"></a>00242 <span class="preprocessor">        #endif</span>
<a name="l00243"></a>00243 <span class="preprocessor"></span>        
<a name="l00244"></a>00244         qDebug() &lt;&lt; <span class="stringliteral">&quot;QNamedPipeThread::~QNamedPipe() &lt;- return&quot;</span>;
<a name="l00245"></a>00245         }
<a name="l00246"></a>00246 
<a name="l00247"></a>00247 <span class="comment">// accessing</span>
<a name="l00248"></a>00248 QString QNamedPipe::getInputFilePath()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> pathIn; }
<a name="l00249"></a>00249 QString QNamedPipe::getOutputFilePath()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> pathOut; }
<a name="l00250"></a>00250 QString QNamedPipe::getPipeName()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> name; }
<a name="l00251"></a>00251 <span class="keywordtype">int</span> QNamedPipe::namedPipesNum = 0;
</pre></div></div>
</td></tr></table>

<br /><hr><br />
<center><a href="http://perception.inf.um.es/QVision">QVision framework</a>.
<a href="http://perception.inf.um.es">PARP research group</a>.
Copyright &copy; 2007, 2008, 2009, 2010, 2011.</center>
<br />
</body>
</html>
